package com.hopes.bizz.packet.hj212.handler;

import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author lyb
 * @version 1.0
 * @date 2023/2/27 14:30
 */

@Component
@ChannelHandler.Sharable
@Slf4j
public class Hj212ChannelInboundHandler extends ChannelInboundHandlerAdapter {

    @Autowired
    private Hj212DataSendHandler hj212DataSendHandler;

    /**
     * 客户端与服务端第一次建立连接时 执行
     */
    @Override
    @SneakyThrows
    public void channelActive(ChannelHandlerContext ctx) {
        super.channelActive(ctx);
        log.info("连接已建立。。。。准备发送数据");
//        while (true) {
//            if (real != null && real) {
//                send(ctx, HJ212Constant.COMMAND_REAL_TIME_DATA);
//            }
//
//            if (min != null && min) {
//                send(ctx, HJ212Constant.COMMAND_MINUTE_DATA);
//            }
//
//            if (hour != null && hour) {
//                send(ctx, HJ212Constant.COMMAND_HOUR_DATA);
//            }
//
//            if (day != null && day) {
//                send(ctx, HJ212Constant.COMMAND_DAY_DATA);
//            }
//            TimeUnit.MINUTES.sleep(minInterval);
//        }

    }
}
